package Dedup;

import java.io.IOException;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.Mapper;

public class DedupMapper extends Mapper<LongWritable, Text, Text, NullWritable>{
    private Text outputKey = new Text();
    private NullWritable outputValue =NullWritable.get();
    private static String[] info;
    @Override
    protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, NullWritable>.Context context)
            throws IOException, InterruptedException {
        info=value.toString().split(",");
            outputKey.set(info[1]);
            context.write(outputKey, outputValue);
    }

}
